package com.qf.springcloud.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface ConsumerStream {

    @Input(value = "stream-queue")
    SubscribableChannel input();

}
